012966685a7fbb4e6c4a1c049b6d6ac6b940fdf5,staging/maven-plugin/src/main/java/org/sonatype/nexus/maven/staging/deploy/strategy/AbstractStagingDeployStrategy.java,AbstractStagingDeployStrategy,initRemoting,#MavenSession#StagingParameters#,80
Before Change
StagingWorkflowV2Service service = remoting.getStagingWorkflowV2Service();
//service.setProgressTimeoutMinutes();
//service.setProgressPauseDurationSeconds();
service.setProgressMonitor(new ProgressMonitor()
{
private boolean needsNewline;
private void maybePrintln() {
if (needsNewline) {
System.out.println();
needsNewline = false;
}
}
@Override
public void start() {
getLogger().debug("START");
}
@Override
public void tick() {
if (getLogger().isDebugEnabled()) {
getLogger().debug("TICK");
}
else {
needsNewline = true;
System.out.print(".");
}
}
@Override
public void pause() {
getLogger().debug("PAUSE");
}
@Override
public void info(String message) {
maybePrintln();
getLogger().info(" * " + message);
}
@Override
public void error(String message) {
maybePrintln();
getLogger().error(" * " + message);
}
@Override
public void stop() {
maybePrintln();
getLogger().debug("STOP");
}
@Override
public void timeout() {
maybePrintln();
getLogger().warn("TIMEOUT");
}
@Override
public void interrupted() {
maybePrintln();
getLogger().warn("INTERRUPTED");
}
});
}
protected synchronized Remoting getRemoting()
After Change
// install and configure progress monitor
StagingWorkflowV2Service service = remoting.getStagingWorkflowV2Service();
service.setProgressMonitor(new ProgressMonitorImpl(getLogger()) {
@Override
public void info(final String message) {
super.info(" * " + message);
}
@Override
public void error(final String message) {
super.error(" * " + message);
}
});
// TODO: Configure these bits
//service.setProgressTimeoutMinutes();